package ct.producer;

import ct.common.bean.Producer;
import ct.producer.Bean.LocalFileProducer;
import ct.producer.io.LocalFileDataIn;
import ct.producer.io.LocalFileDataOut;

import java.io.IOException;

/**
 * @Author Jeremy Zheng
 * @Date 2021/2/10 21:21
 * @Version 1.0
 */
//启动对象
public class Bootstrap {
    public static void main(String[] args) throws IOException {

        if (args.length < 2) {
            System.out.println("系统参数不正确，请按照指定格式传递：（java -jar Produce.jar path1 path2）");
            System.exit(1);
        }

        //构建生产者对象
        Producer producer = new LocalFileProducer();

//        producer.setIn(new LocalFileDataIn("E:\\zmyy\\大三\\项目\\大数据实战电信客服\\2.资料\\辅助文档\\contact.log"));
//        producer.setOut(new LocalFileDataOut("E:\\zmyy\\大三\\项目\\大数据实战电信客服\\" +
//                "call.log"));

        producer.setIn(new LocalFileDataIn(args[0]));
        producer.setOut(new LocalFileDataOut(args[1]));

        //生产数据
        producer.produce();
        //关闭生产者对象，释放资源
        producer.close();
    }
}
